package com.lzq.mq.client.consumer;

import lombok.Data;
import lombok.Getter;
import lombok.Setter;

/**
 * 拉取到的消费消息实体
 */
@Data
public class ConsumeMessage {

    /**
     * 消息的来源队列id
     */
    private int queueId;

    /**
     * 消息体
     */
    private byte[] body;

}
